package com.msblearn.C_013;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.SynchronousQueue;

/**
 * 容量为0；不可以往里面装东西。也不能装东西。
 * 阻塞等待消费者消费。
 * 用于两个线程直接交互数据
 */
public class T008_SynchronousQueue {

    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> strs =  new SynchronousQueue<>();
        new Thread(()->{
            try {
                System.out.println(strs.take());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
        strs.put("aaa");
        System.out.println(strs.size());
    }
}
